package mq

import "fmt"

type Subscriber struct {
	name string
}

func (subscriber *Subscriber) Work(events chan Event) {
	for {
		e, ok := <-events
		if !ok {
			fmt.Printf("没有事件了")
			return
		}
		e.Run()
	}
}
